package org.apache.flink.runtime.rest.messages;

import java.util.Collection;
import java.util.Collections;

/** Message parameters which require a job path parameter. */
public class ConsumerMessageParameters extends MessageParameters {

    public final ConsumerIDPathParameter consumerPathParameter = new ConsumerIDPathParameter();

    @Override
    public Collection<MessagePathParameter<?>> getPathParameters() {
        return Collections.singleton(consumerPathParameter);
    }

    @Override
    public Collection<MessageQueryParameter<?>> getQueryParameters() {
        return Collections.emptySet();
    }
}
